package cn.doitedu.utils;

import org.apache.flink.table.functions.ScalarFunction;

import java.util.Arrays;

public class Array2HbaseSerUDF2 extends ScalarFunction {

    public String eval(Double[][] arr){
        StringBuilder sb = new StringBuilder();

        for (Double[] doubles : arr) {
            String str = Arrays.toString(doubles);
            str = str.substring(1, str.length() - 1);

            sb.append(str);
            sb.append("|");
        }

        return sb.toString();
    }
}
